package com.liuyu.common.framework.rocketmq.fallback;

import com.liuyu.common.framework.rocketmq.kits.RocketLevelEnum;
import com.liuyu.common.framework.rocketmq.vo.MqMessage;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;

/**
 * rocket熔断降级对象
 * @author: liuyu
 * @date: 2022/4/11 18:56
 * @version: 1
 */

@Data
@AllArgsConstructor
@NoArgsConstructor
public class RocketFallbackMessage<T> implements Serializable {
    private static final long serialVersionUID = 1428675028218483585L;
    private String method;
    private String topic;
    private Long timeout;
    private RocketLevelEnum level;
    private MqMessage<T> message;
}
